package com.maksdu.LactiveMQ.core;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

import com.maksdu.LactiveMQ.domain.Message;
import com.maksdu.LactiveMQ.domain.MessageHost;

public class LativeExchange implements Exchange {

	private ConcurrentMap<String, MessageHost> hostMap = new ConcurrentHashMap();
	
	@Override
	public void router(Message message) {
		
	}

	@Override
	public void registry(String topic, MessageHost host) {
		
	}

}
